from datetime import datetime
import logging.config
from celery import Celery
from celery_app.config.config import config_dict,tasks_module
from celery_app.config.logger_config import LOGGING_CONFIG

# 实例化celery对象，传递一个名字
celery_app = Celery("celery_app")

# 显式指定 任务函数所在的模块
celery_app.autodiscover_tasks(tasks_module)

# 通过dictConfig加载日志配置
logging.config.dictConfig(LOGGING_CONFIG)

# 导入配置消息
celery_app.conf.update(**config_dict)

# 日志记录器，给任务使用
logger = logging.getLogger("celery_app.tasks")
